const mysql = require('mysql');
const express = require('express');
const router = express.Router();
const { MYSQL_CONF } = require("../config/db")

const connect = mysql.createConnection(MYSQL_CONF)
//需要执行的代码通过sql 传入
//执行
const select = (sql) => {
  // 开始连接
  connect.connect();
  const promise = new Promise((res, rej) => {
    connect.query(sql, (error, results, fields) => {
      if (error) {
        rej(error);
        throw error
      }
      // // 关闭连接
      connect.end(function (err) {
        if (err) {
          console.log('数据库关闭异常');
          return;
        }
        console.log('正常关闭连接');
        res(results);
      });
    })
  })

  return promise
}


//断开连接
// connect.end();
module.exports = select